package com.numberma.userservice.rabbitmq;

import org.springframework.amqp.core.ExchangeTypes;
import org.springframework.amqp.rabbit.annotation.Exchange;
import org.springframework.amqp.rabbit.annotation.Queue;
import org.springframework.amqp.rabbit.annotation.QueueBinding;
import org.springframework.amqp.rabbit.annotation.RabbitListener;

public class InsertUserConsumer {
    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "InsertUser.queue"),
            exchange = @Exchange(name = "User.exchange", type = ExchangeTypes.FANOUT)
    ))
    public void insertUser(String message) {

    }





}
